package cn.doitedu.day05

import cn.doitedu.day01.utils.SparkUtil

/**
 * @Date 22.4.3
 * @Created by HANGGE
 * @Description
 */
object A05_行动算子_Count_min_max {
  def main(args: Array[String]): Unit = {
    val sc = SparkUtil.getSc
    val rdd = sc.parallelize(List(2,1,3,4,5) ,2)
    // 处理的所有元素的个数
    val l = rdd.count()
    val max: Int = rdd.max()
    println(l)
    println(max)
    println(rdd.min())
    println(rdd.first())
    // 获取排序最大的数据   排在后面的  takeOrdered 获取排序在前的
    val res: Array[Int] = rdd.top(2)
    println(res.toList)



  }

}
